package com.ruyuan.ingestion.common;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;

import java.util.Properties;

public interface Persistable {
    void initialize(Properties properties);

    int write(ConsumerRecords<String,String> records) throws Exception;
}